package com.qf.search.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface StreamInput {
    @Input("stream")
    SubscribableChannel input();
}
